var express = require('express');
var app = express();
// 注入 request 模块.用来发起http请求
var request = require('request');

var qs = require('querystring');



app.use(express.static(__dirname + '/public'));
app.get('/',function (a,b) {
	b.sendFile(__dirname+a.url);
});
app.get('/geturl',function (a,b) {
	// 服务端发起ajax请求;
	// 要引入 request 的依赖库,来发起http请求
	if(a.query.url){
		// 发起http请求
		request(a.query.url,function(err,response,body){
			b.send({code:1,msg:JSON.parse(body)});
		})
	}else{
		// 没有参数,报错
		b.send({code:0,msg:'no_url'});
	}
});
app.post('/posturl',function (req,res) {
	var postData = "";
    req.addListener("data", function (data) {
        postData += data;
    });
    /**
     * 这个是如果数据读取完毕就会执行的监听方法
     */
    req.addListener("end", function () {
    	// 格式化字符串为对象
        var query = qs.parse(postData);
        console.log(query);
        request.post(query.url,{form:query},function (err,response,body) {
			res.send({code:1,msg:JSON.parse(body)});
        })
    });

})
app.listen(8000,function () {
	console.log('server_success')
})